package com.mq.util;

import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class DirectRabitConfig {
//	@Bean
//    public Queue TestDirectQueue() {
//        return new Queue("demoDirectQueue",true);  //true 是否持久 
//    }
//	
	@Bean
    DirectExchange lonelyDirectExchange() {
        return new DirectExchange("demoDirectQueue");
    }
 
}
